package org.poem.service;

import com.alibaba.otter.canal.protocol.exception.CanalClientException;
import com.baomidou.mybatisplus.extension.service.IService;
import org.poem.CommonVO;
import org.poem.IdsVo;
import org.poem.datasource.DataAndParametersVo;
import org.poem.datasource.DataSourceQueryVo;
import org.poem.datasource.DataSourceVo;
import org.poem.datasource.table.SchemaVO;
import org.poem.datasource.table.TableVO;
import org.poem.entity.TDatasource;
import org.poem.result.PageableResult;
 ;

import java.util.List;

/**
 * <p>
 * 数据源 服务类
 * </p>
 *
 * @author vinshine
 * @since 2019-10-24
 */
public interface ITDataSourceService extends IService<TDatasource> {

    /**
     * 01-加载数据源首页+分页
     * @param dataSourceQueryVo    查询条件
     * @param pageSize             每页大小
     * @param pageNumber           当前页码
     * @return
     */
    PageableResult<DataSourceVo> findDataSourceList(DataSourceQueryVo dataSourceQueryVo, Integer pageSize, Integer pageNumber);

    /**
     * 02-新建数据源
     * @param dataSourceVo
     * @return
     */
    String addDataSource(DataSourceVo dataSourceVo,Long dataSourceId);


    /**
     * 03-根据数据源id查询数据源详情
     * @param dataSourceId   数据源id
     * @return
     */
    DataSourceVo getDataSourceVoById(Long dataSourceId);

    /**
     * 04-修改数据源
     * @param dataSourceVo
     * @return
     */
    String updateDataSource(DataSourceVo dataSourceVo);

    /**
     * 05-根据数据源id删除数据源
     * @param dataSourceId   数据源id
     * @return
     */
    String deleteDataSourceById(Long dataSourceId);

    /**
     * 06-根据数据源id批量删除
     * @param idsVo          数据源id数组
     * @return
     */
    String deleteDataSource(IdsVo idsVo);

    /**
     *
     * @param subjectId
     * @return
     */
    List<CommonVO> getDatasourceList(Long subjectId);

    /**
     * 测试
     * @param dataSourceVo
     * @throws CanalClientException
     */
    void testDataSource(DataAndParametersVo dataSourceVo) throws CanalClientException, org.poem.exception.CanalClientException;


    /**
     *
     * @param dataSourceVo
     * @return
     */
    List<String> getSchema(DataAndParametersVo dataSourceVo);


    /**
     *
     * @param datasourceId
     * @return
     */
    List<TableVO> getDatabaseBySourceId(String datasourceId);

}
